
package hn.cch

import org.apache.flink.streaming.api.scala.{DataStream, StreamExecutionEnvironment, createTypeInformation}
import org.slf4j.LoggerFactory


object FlinkMain {

    private val logger = LoggerFactory.getLogger(getClass)

    def main(args: Array[String]): Unit = {


        // 2. 创建 Flink 流执行环境
        val env = StreamExecutionEnvironment.getExecutionEnvironment

        // 3. 创建一个简单的数据流
        val dataStream: DataStream[String] = env.fromElements("Hello", "Flink", "Logging")

        // 4. 对数据流进行处理，并打印日志
        val resultStream: DataStream[String] = dataStream.map { value =>
            // 使用 logger 打印日志
            logger.info(s"Processing value: $value")
            value.toUpperCase()
        }

        // 5. 打印结果到控制台（仅用于演示）
        resultStream.print()

        // 6. 启动 Flink 作业
        env.execute("Flink Logging Example")
        logger.info("main")

    }

}
